<?php
require_once(dirname(__FILE__)."/../include/db_mysql.php");

function init_get_productid( $partyid )
{
	$sql = new SqlClass;
	//连接数据库
	$sql->connect();
	//执行sql语句
    $sql_command = "SELECT productId FROM  `product` WHERE partyId = '$partyid';";
    $r = $sql->exec_sql( $sql_command );//保存执行sql的结果

	$row = mysql_fetch_array($r);

	$productid;
	if($row == '') //说明没有找到其partyid字段符合的product记录
	{
		//创建一条product记录，将partyid存入其partyId字段。
		$sql_command = "INSERT INTO  `product`.`product` ( partyId )VALUES ( '$partyid' );";
		$r = $sql->exec_sql( $sql_command );//保存执行sql的结果
		$productid = mysql_insert_id();
		if( $productid == false ) //数据库出问题，插入失败。
		{
			return false;
		}
	}
	else //说明找到了符合partyid的product记录，有可能是多条，也有可能是一条。在这里我们逻辑上设计是只能有一条的。如果得到多条，在这里我们也只是取第一条。
	{
		$productid = $row['productId'];
	}

	//关闭数据库
	$sql->close();
	
	return $productid;
}

?>